package SparkMaster_Worker

class Message {

}

//hashMap用来管理woker的
//比如增加这个worker的最近一次心跳
case class workerInfo(val id: String, val cpu: Int, val ram: Int) {
  var lastHeartBeat = System.currentTimeMillis()
}

case class RegisterWorkerInfo(id: String, cpu: Int, ram: Int)

//当worker 注册成功,服务器返回这样一个对象
case object RegisterWorkerInfo

//woker每隔一定时间有定时器发送给自己的一个消息
case object SendhertBeat

case class HeartBeat(id: String)

case object StartTimeOutWorker

case object RemoveTimeOutWorker
